package my

import org.apache.spark.sql.SparkSessionExtensions


class MySparkSessionExtension extends (SparkSessionExtensions => Unit ){

  override def apply(v1: SparkSessionExtensions): Unit = {
      v1.injectOptimizerRule{
        session => new MyRule(session)
      }
  }
}
